package com.sh.data.engine.application.model.dto.datadev;

import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

import java.util.Date;

/**
 * @author : fuchen
 * @date : 2021/6/16 9:47
 */
@Data
@Schema
public class FlinkTaskRecordResponse {

    @Schema(description = "运行记录ID")
    private Long id;

    @Schema(description = "任务名称")
    private String taskName;

    @Schema(description = "nodeId")
    private Long nodeId;

    @Schema(description = "任务状态 1-运行中 2-成功 3-失败 4-停止 5-暂停")
    private Integer status;

    @Schema(description = "启动时间")
    private Date startTime;

    @Schema(description = "结束时间")
    private Date endTime;

    @Schema(description = "1-FlinkSQL,3-Flink")
    private Integer taskType;

//  @Schema(description = "如果源表中有kafka类型，则返回kafka表")
//  private List<String> kafkaSourceTables;

    @Schema(description = "责任人")
    private String userName;

    @Schema(description = "调度周期 0-每天 1-周一至周五")
    private Integer scheduleType;

    @Schema(description = "运行时长")
    private Long expendTime;

    @Schema(description = "计划开始时间")
    private Date planTime;

    @Schema(description = "创建时间")
    private Date createTime;

    //  @Schema(description = "是否关注 0-未关注 1-已关注")
//  private Integer Isattention;
    @Schema(description = "0-手动执行 1-周期执行")
    private Integer execType;
}
